package com.qs.rocketmq.sc.service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface MySink {

    String myInput = "my_input";

    @Input(myInput)
    SubscribableChannel input();

}
